package com.doit.sparksql.day01

/**
 * @DATE 2022/1/13/14:44
 * @Author MDK
 * @Version 2021.2.2
 * */
object SQL_Parquet01 {
  def main(args: Array[String]): Unit = {
    val spark = SQLUtil.getSession
    val df = spark.read.json("sql_data/json/a.json")
    df.write.parquet("sql_data/parquet")
    df.write.orc("sql_data/orc")
    spark.close()
  }
}
